package org.study4j.message.mq.rabbitmq.consumer;

//@Component
public class MessageConsumer {
//	@Autowired
//	private RequestAndResponseLogDTORepository logDTORepository;
//
//	private ObjectMapper mapper = new ObjectMapper();
//
//	private static final Logger log = LoggerFactory.getLogger(MessageConsumer.class);
//
//	@RabbitHandler
//	@RabbitListener(queues = { "request_response_log_Q" })
//	public void onMessage(Message message, Channel channel) throws Exception {
//		try {
//			String messageJson = new String(message.getBody(), "utf-8");
//			log.info("获取到的消息内容：{}", messageJson);
//			RequestAndResponseLogDTO logDTO = JsonUtil.json2Object(messageJson, RequestAndResponseLogDTO.class);
//
//			// 将信息存储在MongoDB中
//			logDTORepository.save(logDTO);
//
//			// 确认消息被正确消费
//			channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
//		} catch (Exception e) {
//			// TODO: handle exception
//			e.printStackTrace();
//		}
//	}
}
